package com.example.aigc_education.integration;

import com.example.aigc_education.integration.request.ChatMessageRequestV2;
import com.example.aigc_education.rpc.api.v2.ChatServiceProto;
import io.grpc.stub.StreamObserver;

public interface AgentServiceIntegration {

    /**
     * Stream 流式对话
     * @param request 用户消息
     * @param responseObserver 响应观察者
     */
    void stream(ChatMessageRequestV2 request, StreamObserver<ChatServiceProto.ChatMessage> responseObserver);
}
